package com.headcaselabs.orchestra;
import com.headcaselabs.queue.SQSUtils;

public class ClearJobs {
	
	
	
	public static void main(String[] args) throws Exception {
		Configuration conf = Configuration.getConfiguration(args[0]);
		SQSUtils sqsUtils = new SQSUtils(conf);
		sqsUtils.clearJobDirectory();
		for (String q : conf.getQueues()) {
			System.out.println("Clearing Queue:"+q);
			System.out.println("Removed #"+sqsUtils.clearQueue(q)+" messages");
		}
	}

}
